# -*- coding:utf-8 -*- #
import MySQLdb

#引入上层目录模块方法
import sys
sys.path.append("..")
from configure import *

try:
    m_conn = MySQLdb.connect(host=host, user=user, passwd=passwd,
            db=dbname, charset='utf8',connect_timeout=5)
    m_cursor = m_conn.cursor()
except:
    print "连接数据库失败%s" % host
    

def mysql_connction(reconnect=False):
    global m_cursor
    if not reconnect:
        return m_cursor
    try:
        m_conn = MySQLdb.connect(host=host, user=user, passwd=passwd,
                db=dbname, charset='utf8',connect_timeout=5)
        m_cursor = m_conn.cursor()
    except:
        print "重新连接数据库失败%s" % host

    return m_cursor

#def redis_conn():
    #import redis
    #return redis.Redis()

def redis_pipe():
    import redis
    '''
    pipeline我们在linux使用中是经常会碰到的，
    比如 ps -ef|grep python这样查看当前python进程情况的命令，
    在redis中使用基本原理也是一样。
    pipeline让我们可以一次性将多条命令直接交给redis来执行，然后一次性返回所有操作的结果。
    当我们需要批量读写redis的时候，它能够帮我们提高程序的效率。
    '''
    r = redis.Redis(host=rhost, port=rport)
    
    return r.pipeline()

